package com.darren.center.springboot.thread;

public class InterruptDemo {

    public static void main(String[] args) throws InterruptedException {
        Runnable interruptTask = new Runnable() {
            @Override
            public void run() {
                int i = 0;
                try {
                        //在正常运行任务时，经常检查本线程的中断标志位，如果被设置了中断标志就自行停止线程。
                        while (!Thread.currentThread().isInterrupted()) {
                            //休眠100ms
                            Thread.sleep(100);
                            i++;
                            System.out.println(Thread.currentThread().getName() + " " + Thread.currentThread().getState() + " while " + i);
                        }
                    }catch(InterruptedException e){
                        //在调用阻塞方法时正确处理InterruptedException异常。（例如：catch异常后就结束线程）
                        System.out.println(Thread.currentThread().getName() + " " + Thread.currentThread().getState() + " catch InterruptedException");
                    }
                }
            };
        Thread t1 = new Thread(interruptTask, "t1");
        System.out.println(t1.getName()+ " " + t1.getState() + " is new");

        //启动线程t1
        t1.start();
        System.out.println(t1.getName()+ " " + t1.getState() + " is started");

        //主线程休眠300ms，然后主线程个t1发“中断”指令
        Thread.sleep(300);
        t1.interrupt();
        System.out.println(t1.getName()+ " " + t1.getState() + " is interrupted");

        //主线程休眠300ms，然后查看t1的状态
        Thread.sleep(300);
        System.out.println(t1.getName()+ " " + t1.getState() + " is interrupted now");
    }

}
